package com.shop.www.dao;

import com.shop.www.Utils.JDBCUtilsByDruid;

import java.lang.reflect.Field;
import java.sql.*;
import java.util.ArrayList;
import java.util.List;

public class Basicdao<T> {
    public  static int update(String sql, Object... parameters) {//封装dml语句，parameters为?中的参数
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        int update =0;
        try {
            connection = JDBCUtilsByDruid.getConnection();
            preparedStatement = connection.prepareStatement(sql);
            for (int i = 0; i < parameters.length; ++i) {
               if (parameters[i] != null) {
                    try {
                        preparedStatement.setObject(i + 1, parameters[i]);
                    } catch (SQLException e) {
                        e.printStackTrace();
                    }
                }
            }
             update = preparedStatement.executeUpdate();
            return update;
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCUtilsByDruid.close(null, preparedStatement, connection);
        }
        return update;
    }
    public static List<Object> Select(String sql, String className,Object... parameters) throws Exception{
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet set = null;
        Object result = null;
        List<Object> list = null;
        try {
            connection = JDBCUtilsByDruid.getConnection();
            preparedStatement = connection.prepareStatement(sql);
            for (int i = 0; i < parameters.length; ++i) {
                if (parameters[i] != null) {
                    try {
                        preparedStatement.setObject(i + 1, parameters[i]);
                    } catch (SQLException e) {
                        e.printStackTrace();
                    }
                }
            }
            set = preparedStatement.executeQuery();
            ResultSetMetaData rsmd = set.getMetaData();
            //查询结果一共有多少列,数据库表里面有多少个字段（属性）
            int count = rsmd.getColumnCount();
            //创建一个数组来存放结果集中所有的字段名（把每个字段存进数组里面）
            String[] cols = new String[count];
            //循环获取所有的字段名（）
            for(int i = 0;i < cols.length;i ++){
                //把resultSetMetaDate获取的字段存进数组
                cols[i] = rsmd.getColumnName(i+1);
            }
            //创建一个Arraylist存放解析出来的对象
            list = new ArrayList<Object>();
            //获取类的反射，通过包名.类名。开始连接po层的类
            Class clss = Class.forName(className);
            while(set.next()){
                //每次通过反射创建一个对象
                Object obj = clss.newInstance();
                //通过反射获取对象所有的属性，
                Field[] fie = clss.getDeclaredFields();
                //遍历这个对象的所有属性，把数据库查询出来的数据放入类对象中
                for(Field field:fie){
                    //判断·属性的类型,每种类型对应不同的获取属性方法
                    if(field.getType().getName().equals("java.lang.Integer")||
                            field.getType().getName().equals("int")){
                        //循环列名数组，找到属性名重名的列，获取这一列的值，给该属性赋值
                        for(int i = 0;i < cols.length;i ++){
                            //如果找到这一列
                            if(cols[i].equalsIgnoreCase(field.getName())){
                                //暴力访问
                                field.setAccessible(true);
                                //把表中查询出来的这一列的值给同名类的同名Int属性
                                field.set(obj, set.getInt(cols[i]));
                            }
                        }
                    }else if(field.getType().getName().equalsIgnoreCase("java.lang.String")){
                        for(int i = 0;i < cols.length;i ++){
                            if(cols[i].equalsIgnoreCase(field.getName())){
                                //暴力访问
                                field.setAccessible(true);
                                //用这一列的值给同名的String属性
                                field.set(obj, set.getString(cols[i]));
                            }
                        }
                    }else if(field.getType().getName().equalsIgnoreCase("java.sql.Date")){
                        for(int i = 0;i < cols.length;i ++){
                            if(cols[i].equalsIgnoreCase(field.getName())){
                                //暴力访问
                                field.setAccessible(true);
                                //用这一列的值给同名的Date属性
                                field.set(obj, set.getDate(cols[i]));
                            }
                        }
                    }else if(field.getType().getName().equalsIgnoreCase("java.lang.Double")||
                            field.getType().getName().equalsIgnoreCase("double")){
                        //循环列名数组，找到属性名重名的列，获取这一列的值，给该属性赋值
                        for(int i = 0;i < cols.length;i ++){
                            //如果找到这一列
                            if(cols[i].equalsIgnoreCase(field.getName())){
                                //暴力访问
                                field.setAccessible(true);
                                //用这一列的值给同名的Double属性
                                field.set(obj, set.getDouble(cols[i]));
                            }
                        }
                    }
                }
                list.add(obj);
            }
            return list;
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
        JDBCUtilsByDruid.close(set,preparedStatement,connection);
        }
        return list;
    }
}